package com.hbisdt.cet.sample.consumer;

import org.apache.rocketmq.spring.core.RocketMQListener;

/**
 * RocketMQ消息消费者
 * selectorExpression: 过滤器标签，该消费者订阅的标签为sell的消息
 * @author : 教学案例
 * @version : 1.0
 * @date : 2025-04-29 15:52
 */
//@Service
//@RocketMQMessageListener(topic = "CarbonTrade", consumerGroup = "default_group",selectorExpression = "sell")
public class RocketMQConsumerFilterTag implements RocketMQListener<String> {
    @Override
    public void onMessage(String message) {
        System.out.println("ConsumerFilterTag 收到消息: " + message);
    }
}
